/**
 * 1.监听类注解@RocketMQMessageListener，其中设置topic、tag、group等属性
 * 2.监听类实现接口 RocketMQListener<T> /RocketMQReplyListener<T,R>(其中T为收信类型，R为复信类型)
 * 3.覆写onMessage(T t)方法处理接收到的消息
 * 4.若需要控制更加细致的接收参数，可以覆写 RocketMQPushConsumerLifecycleListener接口的 prepareStart(DefaultMQPushConsumer consumer)方法
 * 以上数据接收采用的是DefaultMQPushConsumer
 */
package com.example.rocketmqspringbootdemo;

import org.apache.rocketmq.client.log.ClientLogger;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class RocketMqSpringConsumerDemoApplication  {
    public static void main(String[] args) {
        System.setProperty(ClientLogger.CLIENT_LOG_USESLF4J,"true");
        SpringApplication.run(RocketMqSpringConsumerDemoApplication.class, args);
    }
}
